package org.ala.tcp_feign_common.handler;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelOutboundHandlerAdapter;
import io.netty.channel.ChannelPromise;


/**
 * 写消息处理器
 *
 * @author 骆毅(ala)
 * @date 2024年4月19日
 */
public class ByteMessageWriteHandler extends ChannelOutboundHandlerAdapter {

	@Override
	public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
		//	继续向下传播
		ctx.write(msg);
	}
	
	

}
